//package com.sskj.mqtt;
//
//import org.springframework.integration.annotation.MessagingGateway;
//import org.springframework.integration.mqtt.support.MqttHeaders;
//import org.springframework.messaging.handler.annotation.Header;
//import org.springframework.stereotype.Component;
//
///**
// * MqttGateway
// *
// * @author hengzi
// * @date 2022/8/23
// */
//
////@Component
////@MessagingGateway(defaultRequestChannel = "mqttOutboundChannel")
//public interface MqttGateway {
//
//    void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, String data);
//
//    void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS) Integer Qos, String data);
//}
//
